package com.ddxz.data.word.join;


import com.ddxz.data.word.struct.FirstData;
import com.ddxz.data.word.struct.SecondData;
import org.apache.flink.api.common.functions.JoinFunction;

/**
 * class description
 *
 * @author 朱宗刚
 * @version 1.0.0
 * @date 2020/9/3
 */

public class DdxzJoin implements JoinFunction<FirstData, SecondData, String> {
    @Override
    public String join(FirstData first, SecondData second) throws Exception {
        return "null";
    }
}
